import pymysql

# 2) 使用PyMySQL 库建立与 MySQL 的连接，并返回一个 db 对象。connect( )方法中的"localhost" 参数为主机名，"root" 参数为连接 MySQL 的用户名，“密码” 参数为 MySQL
# 的连接密码，“test” 参数表示操作的 MySQL 数据库。
db = pymysql.connect(host='localhost', user='root', password='root', port=3306, database='test')

# 3) 使用 connector 对象的 cursor()方法建立对 MySQL 的操作游标。
cursor = db.cursor()

# 4) 使用字符串编写完成 SQL 语句。这里的 SQL 语句使用 UPDATE SET 更新 employee表的 age 字段，更新条件为 sex 字段值等于"M" .
sql = "UPDATE EMPLOYEE SET AGE= AGE + 1 WHERE SEX='%c'" % 'M'

# 5) 使用 try 和 except 语句执行游标 cursor 的 SQL 语句，并使用 commit()方法提交至MySQL 数据库服务器，rollback。方法表示如果在整个提交过程中出现任何问题，则实现事务性的回滚操作。
try:
    cursor.execute(sql)
    db.commit()
except:
    db.rollback()

# 6) 关闭服务器连接。
db.close()